package com.geek.framework.study.event.reactive.stream;

public class Client {
  public static void main(String[] args) {
    EventPublisher publisher = new EventPublisher();
    publisher.addEventLister(event -> {
      System.out.printf("[Thread : %s] Handles %s [Source : %s]\n",
              Thread.currentThread().getName(),
              event.getClass().getSimpleName(),
              event.getSource());
    });
    publisher.publish("Hello reactive stream publisher");
  }
}
